//package com.dingtone.kafkaclient;
//
//import kafka.consumer.ConsumerIterator;
//import kafka.consumer.KafkaStream;
//
//public class ConsumerMsgTask implements Runnable {
//	private KafkaStream m_stream;
//	private int m_threadNumber;
//
//	public ConsumerMsgTask(KafkaStream stream, int threadNumber) {
//		m_threadNumber = threadNumber;
//		m_stream = stream;
//	}
//
//	public void run() {
//		ConsumerIterator<byte[], byte[]> it = m_stream.iterator();
//		while (it.hasNext()){
//			String strMsg = new String(it.next().message());
//			System.out.println("******[MsgClient]****** receive@ " + m_threadNumber + ": Content "+ strMsg);
//		}
//		System.out.println("Shutting down Thread: " + m_threadNumber);
//	}
//}
